#pragma once

#include <memory>

namespace stream {
class Topic;
class Appender;
}

class SevenRecordTopic {
public:
    SevenRecordTopic();
    ~SevenRecordTopic();

    std::shared_ptr<stream::Topic> topic() const;
    constexpr size_t expectRecord() const {
        return _expectRecord;
    }
	void clear();
private:
    std::shared_ptr<stream::Topic> _topic;
	std::shared_ptr<stream::Appender> _appender;
    const size_t _expectRecord = 7ull;
};
